//package com.ruoyi.system.service.activemq;
//
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.jms.core.JmsMessagingTemplate;
//import org.springframework.stereotype.Component;
//
//import javax.jms.Destination;
//import javax.jms.Queue;
//import javax.jms.Topic;
//
///**
// * @description:
// * @author: zhengxiong.jiang
// * @createDate: 2023/2/9
// * @version: 1.0
// */
////我的生产者
//@Component
//public class MyProducer {
//
//
//    @Autowired
//    private JmsMessagingTemplate jmsMessagingTemplate;
//
//    //这个是在MQConfig配置中的队列Bean对象
//    @Autowired
//    private Queue queue;
//
//    @Autowired
//    private Queue queue2;
//
//    //这个是在MQConfig配置中的主题Bean对象
//    @Autowired
//    private Topic topic;
//
//    @Autowired
//    private Topic topic01;
//
//    @Autowired
//    private Topic topic02;
//
//    //发送队列
//    public void sendQueue(String msg){
//        this.sendMessage(this.queue,msg);
//    }
//
//    public void sendQueue2(String msg){
//        this.sendMessage(this.queue2,msg);
//    }
//
//    //发送主题
//    public void sendTopic(String msg){
//        this.sendMessage(this.topic01,msg);
//    }
//
//    //发送主题
//    public void sendTopic02(String msg){
//        this.sendMessage(this.topic02,msg);
//    }
//
//    //发送消息，destination是发送到的队列，message是待发送的消息
//    private void sendMessage(Destination destination, final String message){
//        jmsMessagingTemplate.convertAndSend(destination,message);
//    }
//
//
//}
